package com.ds.consumer;


//@Slf4j
//@RocketMQMessageListener(consumerGroup = "test_group", topic = "test")
//@Component
//public class MsgSendConsumer implements RocketMQListener<MessageExt> {
//
//
//    @Override
//    public void onMessage(MessageExt dto) {
//        MDC.put(TraceIdConstant.TRACE_ID, dto.getUserProperty(TraceIdConstant.TRACE_ID));
//        log.info("MsgSendConsumer onMessage: " + dto);
//    }
//
//
//}
